package com.gengzp.mq.server.model.thread;

import com.gengzp.mq.server.model.message.entity.MqMessage;

/**
 * @ClassName MqThreadWaiter
 * @Description 消息线程阻塞等待者实体类
 * @Author gengzp
 * @Date 2025/9/3 14:47
 */
public class MqThreadWaiter {

    /**
     * 等待的线程
     */
    private Thread thread;

    /**
     * 唤醒时需要返回的消息
     */
    private MqMessage mqMessage;

    /**
     * 开始等待时间戳
     */
    private long startWaitTimeStamp;

    public Thread getThread() {
        return thread;
    }

    public void setThread(Thread thread) {
        this.thread = thread;
    }

    public MqMessage getMqMessage() {
        return mqMessage;
    }

    public void setMqMessage(MqMessage mqMessage) {
        this.mqMessage = mqMessage;
    }

    public long getStartWaitTimeStamp() {
        return startWaitTimeStamp;
    }

    public void setStartWaitTimeStamp(long startWaitTimeStamp) {
        this.startWaitTimeStamp = startWaitTimeStamp;
    }

}
